package xin.alum.aim.groups;

import xin.alum.aim.model.Transportable;

/**
 * 集群处理工厂
 *
 * @author Alum(alum @ live.cn)
 * @date 2021/8/17 19:26
 */
public interface ClusterFactory {

    /**
     * 默认集群消息队列长度
     */
    int QUEUE_CAPACITY = 1024;

    /**
     * 互踢
     *
     * @param session
     */
    void kick(Session session);

    /**
     * 推送
     *
     * @param event
     */
    void push(String recipient, Transportable event);
}
